package com.neusoft.neu24.nep.cfg;

import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.function.Consumer;

@Slf4j
@Configuration
public class RecStr2Consumer {

    @Bean
    public Consumer<String> custom() {
        return str -> {
            log.info("创建消费者  ------ > RecStrConsumer 22222222222222222");
            log.info("接收字符串，im-group-topic2，---" + str);
        };
    }

}
